package com.fishleap.registry;

import com.fishleap.util.CuratorUtils;

import java.net.InetSocketAddress;

/**
 * @author zlg
 * 基于Zk实现服务注册
 */
public class ZkServiceRegistry implements ServiceRegistry {

    /**
     * 服务注册
     * @param serviceName 服务名称
     * @param inetSocketAddress 提供服务的地址
     */
    @Override
    public void registryService(String serviceName, InetSocketAddress inetSocketAddress) {
        // 从命名空间下注册子节点
        // eg: /zdy-rpc/com.fishleap.service.IUserService/127.0.0.7:8888
        String servicePath = "/" + serviceName + inetSocketAddress.toString();
        // 创建临时节点
//        CuratorUtils.createPersistentNode(servicePath);
        CuratorUtils.createEphemeralNode(servicePath);
    }
}
